package com.event.streaming.common

import org.apache.spark.sql.SparkSession

trait Runnable {
  //method
  def run(spark: SparkSession): Unit
}
